package com.example.dddsample.domain.repository;

import com.example.dddsample.domain.entity.KafkaAggregate;

/**
 * @author: bebm
 * @date: 2022/4/6 14:35
 * @description:
 */
public interface KafkaTopicOperExt {

    /**
     * 新增topic
     * @param kafkaAggregate
     */
    void createTopic(KafkaAggregate kafkaAggregate);

    /**
     * 删除topic
     * @param kafkaAggregate
     */
    void deleteTopic(KafkaAggregate kafkaAggregate);

}
